package cn.vcjf.washcar.common.util.weixin;

import cn.vcjf.washcar.common.util.SysParamUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONException;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.ParseException;

/**
 * Created by jauyang on 2017/5/19.
 */

public class WechatUtils{
	
	private static Logger log = Logger.getLogger(WechatUtils.class);
	//公众号
    public static String APPID = SysParamUtil.getParam("vc.wechat.appid");
    public static String APPSECRET = SysParamUtil.getParam("vc.wechat.appsecret");
    
    private static String ACCESS_URL = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=APPID&secret=APPSECRET&code=CODE&grant_type=authorization_code";
    private static String SEND_MSG_URL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=ACCESS_TOKEN";

	/**
	 * 根据code获取微信授权的openid
	 * @param request
	 * @param response
	 * @return
	 * @throws IOException
	 */
    public static String getOpenId(HttpServletRequest request, HttpServletResponse response) throws IOException {
        try {
            request.setCharacterEncoding("UTF-8");
            response.setCharacterEncoding("UTF-8");
            //获取OAuth2.0请求后，服务器返回的code内容,这个code在接下来向微信服务请求用户信息的时候要用到
            String code = request.getParameter("code");
            if(StringUtils.isEmpty(code)){ return null; }
            //将请求用户的URL中的///参数替换成真正的内容
            String requestUrlString = ACCESS_URL.replace("APPID", APPID).replace("APPSECRET", APPSECRET).replace("CODE", code);
            //创建url连接
            URL url = new URL(requestUrlString);
            //打开连接
            HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
            urlConnection.setDoOutput(true);
            urlConnection.setDoInput(true);
            urlConnection.setRequestMethod("GET");
            urlConnection.setUseCaches(false);
            urlConnection.connect();
            BufferedReader reader = new BufferedReader(new InputStreamReader(urlConnection.getInputStream(), "utf-8"));
            StringBuffer buffer = new StringBuffer();
            String line = "";
            //用来接收用户的appid
            String openid = "";
            while ((line = reader.readLine()) != null) {
                buffer.append(line);
            }
            String result = buffer.toString();
            //将服务器返回的字符串转换成json格式
            JSONObject resultObject = JSON.parseObject(result);
            //获取得到用户openid
            openid = resultObject.getString("openid");
            log.debug("获取到的code为："+code);
            log.debug("获取到的openID为："+openid);
            request.setAttribute("code", code);
            request.setAttribute("openid", openid);
            return openid;
        } catch (JSONException e) {
            e.printStackTrace();
        }
        return null;

    }
    /**
     * @method sendWechatmsgToUser
     * @描述: TODO(发送模板信息给用户) 
     * @参数@param touser  用户的openid
     * @参数@param templat_id  信息模板id
     * @参数@param url  用户点击详情时跳转的url
     * @参数@param topcolor  模板字体的颜色
     * @参数@param data  模板详情变量 Json格式
     * @参数@return
     * @返回类型：String
     * @作者:THINK 
     * @时间:2017年6月23日 下午5:55:49
     */
    public static JSONObject sendWechatmsgToUser(String touser, String templat_id, String clickurl, String topcolor, JSONObject data){
    	JSONObject jsonobject = new JSONObject();
    	String token="";
		try {
			//刷新凭证
			WechatAccessToken.getInstance();
			//获取微信凭证，access_token
			token = WechatAccessToken.get();
		} catch (IOException e1) {
			log.error("获取到微信凭证IO异常");
			e1.printStackTrace();
			jsonobject.put("code", 10001);
        	jsonobject.put("msg", "获取凭证IO异常");
        	return jsonobject;
		} catch (ParseException e1) {
			log.error("获取到微信凭证json转换异常",e1);
			jsonobject.put("code", 10002);
        	jsonobject.put("msg", "获取凭证json转换异常");
        	return jsonobject;
		} catch (Exception e) {
			log.error("获取到微信凭证异常",e);
			jsonobject.put("code", 10008);
        	jsonobject.put("msg", "获取凭证异常");
        	return jsonobject;
		}
    	log.debug("获取到微信凭证成功");
        String url = SEND_MSG_URL.replace("ACCESS_TOKEN", token);
        JSONObject json = new JSONObject();
        try {
            json.put("touser", touser);
            json.put("template_id", templat_id);
            json.put("url", clickurl);
            json.put("topcolor", topcolor);
            json.put("data", data);
        } catch (JSONException e) {
        	log.error("接口参数json转换异常",e);
        	jsonobject.put("code", 10003);
        	jsonobject.put("msg", "接口参数json转换异常");
        	return jsonobject;
        }
        String result = httpsRequest(url, "POST", json.toString());
        if(result.equals("ConnectException")){
        	log.error("发送信息接口连接异常");
        	jsonobject.put("code", 10004);
        	jsonobject.put("msg", "发送信息接口连接异常");
        	return jsonobject;
        }
        if(result.equals("RequestException")){
        	log.error("发送信息接口响应异常");
        	jsonobject.put("code", 10005);
        	jsonobject.put("msg", "发送信息接口响应异常");
        	return jsonobject;
        }
        try {
            JSONObject resultJson = JSON.parseObject(result);
            String errmsg = (String) resultJson.get("errmsg");
            if(!"ok".equals(errmsg)){  //如果为errmsg为ok，则代表发送成功，公众号推送信息给用户了。
            	log.debug("【发送信息失败】 code:"+resultJson.getString("errcode") +",errmsg:"+resultJson.getString("errmsg"));
            	jsonobject.put("code", 10006);
            	jsonobject.put("msg", "发送信息失败");
            	return jsonobject;
            }
        } catch (JSONException e) {
        	log.error("返回消息json转换异常");
            e.printStackTrace();
            jsonobject.put("code", 10007);
        	jsonobject.put("msg", "返回消息json转换异常");
        	return jsonobject;
        }
        log.debug("【发送信息成功】");
        jsonobject.put("code", 10000);
    	jsonobject.put("msg", "发送信息成功");
        return jsonobject;
    }
    
    /**
     * @method packJsonmsg //消息OPENTM400514061 收款成功通知
     * @描述: TODO(封装微信模板:订单支付成功) 
     * @参数@param first  头部
     * @参数@param orderMoneySum 付款金额
     * @参数@param merchantName  商户名称
     * @参数@param payType  		支付方式
     * @参数@param orderNo		交易单号
     * @参数@param orderDate		交易时间
     * @参数@param remark  		说明
     * @返回类型：JSONObject
     * @作者:THINK 
     * @时间:2017年6月24日 下午2:04:05
     * 
     */
    public static JSONObject packJsonmsg(String first, String orderMoneySum, String merchantName, String payType, String orderNo, String orderDate, String remark, String fontColor){
        JSONObject json = new JSONObject();
        try {
            JSONObject jsonFirst = new JSONObject();
            jsonFirst.put("value", first);
            jsonFirst.put("color", fontColor);
            json.put("first", jsonFirst);
            
            JSONObject jsonOrderMoneySum = new JSONObject();
            jsonOrderMoneySum.put("value", orderMoneySum);
            jsonOrderMoneySum.put("color", fontColor);
            json.put("keyword1", jsonOrderMoneySum);
            
            JSONObject jsonMerchantName = new JSONObject();
            jsonMerchantName.put("value", merchantName);
            jsonMerchantName.put("color", fontColor);
            json.put("keyword2", jsonMerchantName);
            
            JSONObject jsonPayType = new JSONObject();
            jsonPayType.put("value", payType);
            jsonPayType.put("color", fontColor);
            json.put("keyword3", jsonPayType);
            
            JSONObject jsonOrderNo = new JSONObject();
            jsonOrderNo.put("value", orderNo);
            jsonOrderNo.put("color", fontColor);
            json.put("keyword4", jsonOrderNo);
            
            JSONObject jsonOrderDate = new JSONObject();
            jsonOrderDate.put("value", orderDate);
            jsonOrderDate.put("color", fontColor);
            json.put("keyword5", jsonOrderDate);
            
            JSONObject jsonRemark = new JSONObject();
            jsonRemark.put("value", remark);
            jsonRemark.put("color", fontColor);
            json.put("remark", jsonRemark);
            
        } catch (JSONException e) {
        	log.error("封装微信模板json异常");
            e.printStackTrace();
        }
        return json;
    }
    /**
     * @描述:httpsRequest 请求方法：
     * @作者:THINK 
     * @时间:2017年6月23日 下午5:50:24
     */
    public static String httpsRequest(String requestUrl, String requestMethod, String outputStr){
        try {
            URL url = new URL(requestUrl);
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            // 设置请求方式（GET/POST）
            conn.setRequestMethod(requestMethod);
            conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
            // 当outputStr不为null时向输出流写数据
            if (null != outputStr) {
                OutputStream outputStream = conn.getOutputStream();
                // 注意编码格式
                outputStream.write(outputStr.getBytes("UTF-8"));
                outputStream.close();
            }
            // 从输入流读取返回内容
            InputStream inputStream = conn.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String str = null;
            StringBuffer buffer = new StringBuffer();
            while ((str = bufferedReader.readLine()) != null) {
                buffer.append(str);
            }
            // 释放资源
            bufferedReader.close();
            inputStreamReader.close();
            inputStream.close();
            inputStream = null;
            conn.disconnect();
            return buffer.toString();
        } catch (ConnectException ce) {
            log.error("连接超时：{}",ce);
            return "ConnectException";
        } catch (Exception e) {
        	log.error("https请求异常：{}",e);
            return "RequestException";
        }
    }
//    
//    @SuppressWarnings("static-access")
//	public static void main(String[] args) {
//    	try {
//    		WechatAccessToken.setAccesstoken("oldAccesstoken");
//    		WechatAccessToken.setActiveTime("2017/06/23 17:00:00");
//			WechatAccessToken.getInstance().get();
//		} catch (ParseException e) {
//			e.printStackTrace();
//		} catch (IOException e) {
//			e.printStackTrace();
//		}
//	}

}
